62221c0d14ae3abe7672cb13c7b8a76122fe806a,workflow/src/test/java/io/rouz/task/TaskEvalBehaviorTest.java,TaskEvalBehaviorTest,shouldEvaluateInputsInParallelForCurriedTask,#,408

Before Change


  @Test
  public void shouldEvaluateInputsInParallelForCurriedTask() throws Exception {
    AtomicBoolean processed = new AtomicBoolean(false);
    Task<String> task = Task.named("WithInputs").<String>curryTo()
        .in(() -> leaf("A"))
        .in(() -> leaf("B"))
        .in(() -> leaf("C"))
        .process(c -> b -> a -> {

After Change


  @Test
  public void shouldEvaluateInputsInParallelForCurriedTask() throws Exception {
    AtomicBoolean processed = new AtomicBoolean(false);
    Task<String> task = Task.ofType(String.class).named("WithInputs").curried()
        .in(() -> leaf("A"))
        .in(() -> leaf("B"))
        .in(() -> leaf("C"))
        .process(c -> b -> a -> {